package com.yan.common.mq.xml;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

import java.util.Map;

/**
 * Created by yanl_ on 2018/5/4.
 */
@Service
public class Comsumer {

    @RabbitListener(queues = "queue.lotus.payment.notify")
    public void handleOrderNotify(Message message) {
        try {
            String msg = new String(message.getBody(), "utf-8");
            System.out.println("Receiver xml context ##############################: " + message + "  " + msg);
        } catch (Exception e) {
            e.printStackTrace();

        }
    }
}
